package com.itc.bi.constant;

/**
 * @BelongsProject: itc-airport-cloud
 * @BelongsPackage: com.itc.bi.constant
 * @Author: hecaiy
 * @CreateTime: 2024-07-03  09:17
 * @Description: TODO
 * @Version: 1.0
 */
public interface KafkaConstant {

    /**
     * 数据集加工消息
     */
    String KAFKA_TOPIC_DATA_SET_PROCESS = "dataSetProcessDB";

    /**
     * python数据加工操作
     */
    String KAFKA_TOPIC_DATA_SET_PYTHON = "dataSetPython";

    /**
     * SQL数仓中附表名称 sql_slave_dtId
     */
    String DATA_SET_TYPE_SQL_SLAVE = "sql_slave_";

    /**
     * SQL数仓中主表名称 sql_master_dtId
     */
    String DATA_SET_TYPE_SQL_MASTER = "sql_master_";

    /**
     * PYTHON数仓中主表名称 py_master_dtId
     */
    String DATA_SET_TYPE_PYTHON_SLAVE = "py_slave_";

    /**
     *  PYTHON数仓中附表名称 py_slave_dtId
     */
    String DATA_SET_TYPE_PYTHON_MASTER = "py_master_";

    /**
     * sql数据集创建数据同步
     */
    String KAFKA_TOPIC_DATA_SET_SQL = "dataSetSQL";

    /**
     * python数据同步成功
     */
    String KAFKA_TOPIC_DATA_SET_PYTHON_SUCCESS="dataSetPythonSuccess";

    /**
     * mqtt数据接收处理
     */
    String MQTT_DATA_ACCEPT="mqtt_data_accept";
    /**
     * 数据通知执行
     */
    String DATA_SYN_ACCEPT="datasyntopic";

    /**
     * 数据项更新
     */
    String KAFKA_TOPIC_DATA_SET_COLUMN_EDIT = "dataSetClumnEdit";
}
